package com.sikaryofficial.adaptermq.message.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * input 消费者定义
 *
 *
 * @Description: MySink
 */
public interface MQConsumer {
    String CANAL_DATA_SYNC_INPUT = "canal_hismk_sync_data";

    @Input(CANAL_DATA_SYNC_INPUT)
    SubscribableChannel canalDataSyncInput();

}
